package cn.getech.data.development.sink.sync

import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment

trait FlinkRealtimeCollectTrait[T] {

  /**
    * 覆盖数据
    */
  def overwriteTable

  /**
    * json sink
    */
  def sinkJson(env: StreamExecutionEnvironment)

  /**
    * text csv sink
    */
  def sinkCsv(tEnv: StreamTableEnvironment)
}
